package rpc;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;
import java.net.InetSocketAddress;

/**
 * 作者：吴超
 * 邮箱：wuchao_19931120@163.com
 * 时间：2022-01-04
 * 描述：
 */

public class HDFSClient {

    public static void main(String[] args) throws IOException {
        // 代理服务器
        RPCProtocol clinent = RPC.getProxy(RPCProtocol.class, RPCProtocol.versionID, new InetSocketAddress("localhost",8888), new Configuration());
        System.out.println("客户端开始工作！");
        clinent.mkdirs("/input");
    }

}
